package com.pactera.rabbitmq.service.consumer;

import com.alibaba.fastjson.JSON;
import com.pactera.rabbitmq.bean.MessageInfo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 实时数据同步处理类
 *
 * @author: liqingdian
 **/
public abstract class RtdsAccept implements Accept {
    private static final Logger log = LoggerFactory.getLogger(RtdsAccept.class);

    @Override
    public void accept(MessageInfo messageInfo) {
        log.info("处理接收的消息数据: \n{}", JSON.toJSONString(messageInfo));
    }
}
